package org.poem.enums;

/**
 * 数据库的类型
 * @author poem
 */
public enum EnumDataType {
    /**
     * null
     */
    NULL("",""),
    /**
     * mysql
     */
    MYSQL("mysql",KafkaEnums.DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC_MYSQL),

    /**
     * postgres
     */
    POSTGRES("postgres",KafkaEnums.DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC_POSTGRES),
    /**
     * oracle
     */
    ORACLE("oracle",KafkaEnums.DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC_SQLSERVER),

    /**
     * oracle
     */
    SQLSERVER("sqlserver",KafkaEnums.DATA_FULL_TRANSFORM_TO_PRODUCER_TOPIC_SQLSERVER);


    private String type;
    private String topic;

    EnumDataType(String type,String topic) {
        this.type = type;
        this.topic = topic;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getType() {
        return type;
    }

    @Override
    public String toString() {
        return type;
    }
}
